﻿using System;
using System.Collections.Generic;
using System.Text;
using System.Threading.Tasks;

namespace Ec.NETCoreFramework.Common.MQ
{
    public abstract class TaskInterface
    {
        /// <summary>
        /// 是否在确认放回队列
        /// </summary>
        public bool IsAck { get; set; }
        public DateTime FileInfoLastTime { get; set; }
        public string ExchangeName { get; set; }
        public abstract string QueueName();
        public abstract void SetConsumeConfig(byte[] consumeConfig);

        public abstract Task<bool> ConsumeEvent(byte[] message);
    }
}
